儒猿儒猿中间件 RocketMQ 从0开始带你成为消息中间件实

从 0 开始带你成为消息中间件实战高手.txt

标签：儒猿儒猿中间件 RocketMQ 从0开始带你成为消息中间件实

从 0 开始带你成为消息中间件实战高手

美团三面：消息中间件实现高可用架构，你会怎么设计？

标签：架构 java 中间件

对于一个合格的高级Java工程师而言，你肯定会碰到在系统里用到MQ的场景，那么这个时候你需要基于你的业务场景和需求，考虑在使用MQ的时候可能遇到的一些技术问题

0.实践部署一个RocketMQ集群保证消息中间件的高可用

标签： java RocketMQ

以下部分内容来源借鉴于儒猿技术窝以及RocketMQ官方文档目前要做到的是实现RocketMQ的高可用，总体的部署架构如下也就是说，NameServer会部署3个节点，来保证所有的broker能够注册到NameServer上面，哪怕...

做了几年开发，你知道自己的系统为什么要用消息中间件吗？

标签：面试中间件 java

这篇文章开始，我们会把消息中间件这块高频的面试题给大家说一下，也会涵盖一些MQ中间件常见的技术问题。

RocketMQ消息中间件用起来真的可靠吗？

标签：后端 rabbitmq java

这篇文章开始，我们先深入的分析一下消费者手动ack机制保证消息不丢失的底层原理，然后来讲解生产者保证消息不丢失的confirm机制

电商营销场景的RocketMQ实战01-RocketMQ原理

标签： java-rocketmq rocketmq java

物理存储结构主要是为了优化写入和读取，都是为了写入、存储、读取，这三块去做一个设计的，写入尽可能高吞吐，高并发，如何让存储可以有效的进行数据结构组织服务于我们的写入和读取，如何让高并发的读取可以...

RocketMQ源码解析十（定时消息（延时消息）流程）

标签： RocketMQ

定时消息是指消息发送到Broker后，并不立即被消费者消费而是要等到特定的时间后才能被消费，RocketMQ不支持任意的时间精度。发送消息时，只要给消息设置一个延时级别message.setDelayTimeLevel(3)，消息发送到...

RocketMQ源码解析八（Consumer并发消费消息）

标签： RocketMQ

回顾一下消息拉取，PullMessageService 负责对消息队列进行消息拉取，从远端服务器拉取消息后将消息存人ProcessQueue消息队列处理队列中，然后调用ConsumeMessageService#submitConsumeRequest方法进行消息消费，...

冒着被女朋友骂的风险，也要花时间整理的RocketMQ技术总结

标签： java 编程语言人工智能

68特惠价原价 99 的《从0开始带你成为消息中间件实战高手》=== 课程内容====== 课程内容 ====== 适合人群===●无论你是Java初/中/高级工程师、Java架构师、大数据工程师●充分吸收专栏内容，JVM实战能力必将有质的...

RocketMQ源码解析九（消息消费失败重试流程）

标签： RocketMQ

Consumer 直接从ConsumeMessageConcurrentlyService发送重试消息方法开始

RocketMQ源码解析三（Producer发送消息——同步消息）

标签： RocketMQ

发送消息的示例：

RocketMQ源码解析四（Broker接收以及存储消息）

标签： RocketMQ

接收请求的入口已经在上篇分析过了，所以这里直接看处理器如何处理请求。

RocketMQ源码解析七（Consumer拉取消息流程）

标签： RocketMQ

这里基于PUSH模式和集群模式来分析消息拉取机制。在Consumer启动的时候，会开启一个线程，专门用来拉取消息。

RocketMQ源码解析十二（顺序消息流程）

标签： RocketMQ

顺序消费稍微复杂点，主要是顺序消费对重平衡以及消息拉取都有影响。

RocketMQ每秒要写入几十万并发，是怎么实现的？

标签： rocketmq kafka java

Kafka是高吞吐低延迟的高并发、高性能的消息中间件，在大数据领域有极为广泛的运用。配置良好的Kafka集群甚至可以做到每秒几十万、上百万的超高并发写入。

从Synchronized到CAS，带你彻底弄懂Java里的各种锁！

标签：分布式中间件编程语言

目录一、前情回顾二、场景引入，问题凸现三、初步的解决方案：synchronized四、更高效的方案：Atomic原子类及其底层原理五、Java 8对CAS机制的优化六、总结 & 思考一、前情回顾上篇文章给大家聊了一下volatile的...

RocketMQ源码解析五（Consumer启动流程）

标签： RocketMQ

Consumer示例：

RocketMQ源码解析十三（事务消息流程）

标签： RocketMQ

代码示例

RocketMQ（六）高级特性及原理

一、消息幂等性问题保证消息幂等性就是保证多次相同的请求时，消费者只执行这些相同请求中的一个 aa

RocketMQ源码解析十一（Consumer上报消费进度流程（集群模式））

标签： RocketMQ

Consumer 在消费者启动过程中，会启动MQClientInstance，而MQClientInstance中会启动多个定时任务，其中就包括定时上报消费进度：

RocketMQ源码解析六（Consumer重平衡流程）

标签： RocketMQ

重平衡服务是在Consumer启动的时候启动的一个后台线程，每次重平衡后过20s后再发起一次重平衡

RocketMQ源码解析二（Broker启动流程）

标签： RocketMQ

启动流程

2021-07-14

标签：面试 java spring

河小马(儒猿技术窝管理员): 计算机网络，netty 这个学了之后网络层面基本没有任何问题了。分布式锁，分布式事务，分布式全局id 这三大模块的视频一定要学，将会成为你简历中的一个亮点。因为公司实际却是有相关...

RocketMQ源码解析一（NameServer启动流程）

标签： RocketMQ

从启动类开始看

儒枭：我看技术人的成长路径

标签：编程语言人工智能 systemd

儒枭读完需要20分钟速读仅需 3 分钟1 为什么要成长成长是为了在职场升值，提升职场竞争力！衡量标准：你成长的速度要匹配甚至超越业务发展的速度。当你成长速度超越业务发展速度的时候，组...

阿里面试官都没想到，一个volatile我能跟他扯上半小时！

标签：分布式中间件编程语言

提醒一、场景引入，问题初现很多同学出去面试，都会被问到一个常见的问题：说说你对volatile的理解？不少初出茅庐的同学可能会有点措手不及，因为可能就是之前没关注过这个。但是网上百度一下呢，不少文章写的很好...

每次都碰到面试官问我如何保证Kafka不丢失消息，快哭了。。

标签： kafka rabbitmq java

这篇文章，我们来聊聊在线上生产环境使用消息中间件技术的时候，从前到后的全链路到底如何保证数据不能丢失。

095、总复习：线上系统的JVM参数优化、GC问题定位排查、OOM分析解决

标签： jvm

群里有一线大厂助教答疑、专栏优秀作业交流、互联网大厂面经分享、知名互联网公司内推，点击下方链接了解：儒猿技术交流群学员面经分享儒猿技术窝优秀学员作业展示儒猿技术交流群日常技术交流及助教答疑如何加群？...

用完Gradle之后，我开始嫌弃Maven了！

标签：编程语言 python linux

‍‍文章来源：https://www.toutiao.com/article/6824937779193971207/‍‍目录安装gradle使用gradle wrapper依赖管理gradle的任务...但是如果你经常使用Maven，可能会发现Maven有一些地方用的让人不太舒服：一来Ma...

连API接口的安全加密都不会设计，坐等黑客攻击你的接口吧！

标签：安全 https ssl

「关注“石杉的架构笔记”，大厂架构经验倾囊相授」文章来源：【公众号：苏三说技术】前言我们日常开发中，如何保证接口数据的安全性呢？个人觉得，接口数据安全的保证过程，主要体现在这几个方面：一个就是数据传输...